package com.surfilter.massdata.spark.util.ipcheck;
import org.apache.spark.sql.Row;
import scala.collection.Iterator;
import scala.runtime.AbstractFunction1;
import scala.runtime.BoxedUnit;

import java.io.Serializable;
/** 
* @author  hutao
* @date 创建时间：2017年5月22日 下午2:57:35 
* @Description：
* @version 1.0 
* 
**/

public abstract class JavaForeachPartitionDFFunc extends AbstractFunction1<Iterator<Row>, BoxedUnit> implements Serializable {
	private static final long serialVersionUID = 1L;

	@Override
    public BoxedUnit apply(Iterator<Row> it) {
        call(it);
        return BoxedUnit.UNIT;
    }
    
    public abstract void call(Iterator<Row> it);
}
